4996d8ffd8fe9cd56751b2daba076fe87e6220a3,fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java,AbstractCrawlerService,delete,#Consumer#,403
Before Change
break;
}
final BulkRequestBuilder bulkBuilder = getClient().prepareBulk();
for (final SearchHit searchHit : searchHits) {
bulkBuilder.add(getClient().prepareDelete(index, type, searchHit.getId()));
}
final BulkResponse bulkResponse = ActionGetUtil.actionGet(bulkBuilder.execute());
if (bulkResponse.hasFailures()) {
throw new EsAccessException(bulkResponse.buildFailureMessage());
}
After Change
while (true) {
final SearchResponse prevResponse = response;
response = getClient()
.get(c -> c.prepareSearchScroll(prevResponse.getScrollId()).setScroll(new TimeValue(scrollTimeout)).execute());
final SearchHits searchHits = response.getHits();
if (searchHits.hits().length == 0) {